package com.codejiwei.flink.cdc;

import org.apache.kafka.common.header.Headers;

/**
 * author: codejiwei
 * date: 2023/8/27
 * desc:
 **/
public class KafkaRecord {

    private long timestamp; // 日志的产生时间

    private String value; // 日志的内容

    private String kafkaTopic; // 出口kafka

    private String kafkaKey;

    private Headers kafkaHeaders;


}
